package com.yangfan.thread.thread_wangwenjun03;

/**
 * @description: 线程强制中断
 * @author: yangfan
 * @date: Created in 2020/1/26 0026 12:36
 * @modified By:
 */
public class ThreadForcedInterrupt {


    /**
     * 场景:系统进行收集 数据，正常情况下 必须在 30秒内 完成，但是他因为一些原因 执行了 1分钟
     * 如果30秒内 无法完成则必须 停止收集工作 否则对其他功能会造成影响
     * <p>
     * {@link ThreadService} 负责收集的线程服务
     */


    public static void main(String[] args) {

        ThreadService ts = new ThreadService();

        ts.dataCollection(() -> {

            while (true) {
                System.out.println("正在执行数据采集工作未完成。。。。。");
            }

        });

        //等待一会
        try {

            Thread.sleep(200);

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

        ts.stopDataCollection(30_000L);

    }


}
